package com.cupdata.sms.kafka;

import com.cupdata.sms.core.CusKafkaProperties;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface MessageDealProcessor<T> {

    CusKafkaProperties getKafkaProperties();
    void preDeal(ConsumerRecords<String,byte[]> records);

    void theadPoolDeal(ConsumerRecord<String,byte[]> record);
    void theadPoolDealException(ConsumerRecord<String,byte[]> record);

    void postDeal(ConsumerRecords<String,byte[]> records);

}
